package aggregation.system.peer.aggregation;

import common.peer.PeerAddress;
import se.sics.kompics.network.Message;

public class NumMessage extends Message {

	private static final long serialVersionUID = -6815596147580962155L;

	protected final PeerAddress source;
	protected final PeerAddress destination;
        protected final double num;
        protected final double estimatedBw;
	

//-------------------------------------------------------------------	
	public NumMessage(PeerAddress source, PeerAddress destination, double num, double estimatedBw) {
		super(source.getPeerAddress(), destination.getPeerAddress());
		this.source = source;
		this.destination = destination;
                this.num=num;
                this.estimatedBw= estimatedBw;
		
	}

//-------------------------------------------------------------------	
	public PeerAddress getMSPeerDestination() {
		return destination;
	}

//-------------------------------------------------------------------	
	public PeerAddress getMSPeerSource() {
		return source;
	}

//-------------------------------------------------------------------	
	public double getNum(){
            return num;
        }
        
        public double getEstimatedBw(){
            return estimatedBw;
        }
}

